package com.shanzhu.oe.service;

import reactor.core.publisher.Flux;

public interface AIService {

     Flux<String> streamQuery(String prompt);
}
